windows下kafka安装启动以及使用

kafka用到了zookeeper，现在的kafka会自带zookeeper，如果我们要自己安装的话 也可以

zookeeper的下载地址为：https://zookeeper.apache.org/releases.html#download

下载成功之后解压，j进入bin目录，然后通过下面的命令启动zookeeper.

在zookeeper使用时，可能会遇到一些错误，关于这些错误的问题可以参考博主的这篇博客：zookeeper安装启动的一些问题

然后我们需要需要下载kafka，kafka的下载地址为：http://kafka.apache.org/downloads

解压并进入Kafka目录，笔者：D:\Kafka\kafka_2.12-0.11.0.0

 进入config目录找到文件server.properties并打开

找到并编辑zookeeper.connect=localhost:2181

Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181

 进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

kafka有自带的zookeeper，启动自带的zookeeper可以通过如下命令：

如果在执行该命令时报错：

则有可能是kafka安装路径中的横杠导致的，这时候我们将kafka拷贝到一个没有横杠的路径下即可。参考：https://stackoverflow.com/questions/20105735/error-the-syntax-of-the-command-is-incorrect-when-renaming-a-file

如果安装没有问题了，使用命令启动单点集群的kafka时，报错：

博主解决的办法是打开，在kafka安装路径下的config/server.properties文件中，修改下面的配置为：

参考：https://stackoverflow.com/questions/47677549/kafka-zookeeper-connection-to-node-1-could-not-be-established-broker-may-no

命令为：

测试该topic是否创建成功：

在本地拷贝两个server.properties

更改下面的参数

broker.id属性是集群中每个节点的唯一且永久的名称。 我们只需要覆盖端口和日志目录，这是因为我们都在同一台计算机上运行它们，并且希望所有代理都不要试图在同一端口上注册或覆盖彼此的数据。

我们有Zookeeper并启动了单个节点，因此我们只需要启动两个新节点：

现在，创建一个具有三个复制factor的新topic：

好的，但是现在有了集群，我们如何知道哪个broker在做什么？我们需要运行“describe topics”命令：

 第一行给出了所有分区的摘要，每一行都给出了有关一个分区的信息。 由于该主题只有一个分区，因此只有一行。

请注意，在我的示例中，节点2是topic唯一分区的leader。我们可以在创建的之前的topic 上运行相同的命令，以查看其信息

因此，如我们期待的一样-之前的topic没有replicas 副本，并且位于服务器0上，这是我们创建群集时集群中唯一的服务器。

让我们向我们的新topic发布一些消息：

然后consume这些message

现在让我们测试一下容错能力。 broker 2扮演的是leader的角色，所以让我们kill它：

在kill之后，leader自动变为了server 1

但是，即使最初进行写操作的leader已经down掉了，message仍然可供使用：

原因在于，我们设置了备份。